import os
from celery import Celery

# 设置 Django 的 settings 模块环境变量
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'DjangoSpark.settings')

# 创建 Celery 应用，命名可以与项目名称相同
app = Celery('Djangospark')

# 从 Django 的 settings 中加载配置，namespace 为 "CELERY"
app.config_from_object('django.conf:settings', namespace='CELERY')

# 自动发现每个 app 中的 tasks.py 模块
app.autodiscover_tasks()
